5bdd54cbd0cdc5a149d980c4b590b6f041dc8ae8,concourse-server/src/main/java/com/cinchapi/concourse/server/ConcourseServer.java,ConcourseServer,sumKeyCriteriaTime,#String#TCriteria#number#AccessToken#TransactionToken#String#,4778
Before Change
findAtomic(queue, stack, atomic);
Set<Long> records = stack.pop();
for (long record : records) {
TObject tObj = sumKeyRecordTimeAtomic(key, record,
timestamp, atomic);
if(tObj != null) {
result = result.add(new BigDecimal(
Convert.thriftToJava(tObj).toString()));
}
}
}
After Change
checkAccess(creds, transaction);
Queue<PostfixNotationSymbol> queue = convertCriteriaToQueue(criteria);
AtomicSupport store = getStore(transaction, environment);
BigDecimal result = new BigDecimal(0);
AtomicOperation atomic = null;
while (atomic == null || !atomic.commit()) {
atomic = store.startAtomicOperation();
try {
Deque<Set<Long>> stack = new ArrayDeque<Set<Long>>();
findAtomic(queue, stack, atomic);
Set<Long> records = stack.pop();
for (long record : records) {
result = sumKeyRecordTimeAtomic(key, record, timestamp,
result, atomic);
}
}
catch (AtomicStateException e) {